package com.lds.memory.kafka.partition;

import java.util.Collection;

public interface Storage<T> {
    /**
     * 存储
     * @param data
     */
    void store(T data);

    /**
     * 获取
     */
    Collection<T> acquire();
}
